from celery_tasks.broker import Broker
from celery_tasks.worker import Worker

class Celery(object):
    def __init__(self):
        self.broker = Broker()
        self.worker = Worker()

    def add(self,func):
        self.broker.broker_list.append()

    def work(self,func):
        self.worker.run(self.broker,func)

from celery_tasks.tasks import send_sms_code

app = Celery()
app.add(send_sms_code)

app.work(send_sms_code)